package com.designPattern.observer;

import java.util.Observable;

/**
 * 消息产生者
 * @author : liutianlong
 * @date : 2023/5/25
 * @since : 1.0
 */
public class MessageProducer extends Observable {

    private String producer;

    public MessageProducer(String producer) {
        this.producer = producer;
    }

    public void createMessage(String message) {
        System.out.println(String.format("%s 发布了一条消息：%s",this.producer,message));
        // 必须要设置状态变化，否则收不到通知
        this.setChanged();
        // 通知订阅者
        this.notifyObservers(message);
    }
}
